type google.golang.org/grpc/internal/transport.loopyWriter

25 uses

	google.golang.org/grpc/internal/transport (current package)
		controlbuf.go#L513: type loopyWriter struct {
		controlbuf.go#L542: func newLoopyWriter(s side, fr *framer, cbuf *controlBuffer, bdpEst *bdpEstimator, conn net.Conn, logger *grpclog.PrefixLogger, goAwayHandler func(*goAway) (bool, error), bufferPool mem.BufferPool) *loopyWriter {
		controlbuf.go#L544: 	l := &loopyWriter{
		controlbuf.go#L586: func (l *loopyWriter) run() (err error) {
		controlbuf.go#L643: func (l *loopyWriter) outgoingWindowUpdateHandler(w *outgoingWindowUpdate) error {
		controlbuf.go#L647: func (l *loopyWriter) incomingWindowUpdateHandler(w *incomingWindowUpdate) {
		controlbuf.go#L664: func (l *loopyWriter) outgoingSettingsHandler(s *outgoingSettings) error {
		controlbuf.go#L668: func (l *loopyWriter) incomingSettingsHandler(s *incomingSettings) error {
		controlbuf.go#L673: func (l *loopyWriter) registerStreamHandler(h *registerStream) {
		controlbuf.go#L683: func (l *loopyWriter) headerHandler(h *headerFrame) error {
		controlbuf.go#L718: func (l *loopyWriter) originateStream(str *outStream, hdr *headerFrame) error {
		controlbuf.go#L736: func (l *loopyWriter) writeHeader(streamID uint32, endStream bool, hf []hpack.HeaderField, onWrite func()) error {
		controlbuf.go#L782: func (l *loopyWriter) preprocessData(df *dataFrame) {
		controlbuf.go#L796: func (l *loopyWriter) pingHandler(p *ping) error {
		controlbuf.go#L804: func (l *loopyWriter) outFlowControlSizeRequestHandler(o *outFlowControlSizeRequest) {
		controlbuf.go#L808: func (l *loopyWriter) cleanupStreamHandler(c *cleanupStream) error {
		controlbuf.go#L837: func (l *loopyWriter) earlyAbortStreamHandler(eas *earlyAbortStream) error {
		controlbuf.go#L852: func (l *loopyWriter) incomingGoAwayHandler(*incomingGoAway) error {
		controlbuf.go#L863: func (l *loopyWriter) goAwayHandler(g *goAway) error {
		controlbuf.go#L875: func (l *loopyWriter) handle(i any) error {
		controlbuf.go#L913: func (l *loopyWriter) applySettings(ss []http2.Setting) {
		controlbuf.go#L937: func (l *loopyWriter) processData() (bool, error) {
		controlbuf.go#L1022: func (l *loopyWriter) updateStreamAfterWrite(str *outStream) error {
		http2_client.go#L83: 	loopy      *loopyWriter
		http2_server.go#L80: 	loopy           *loopyWriter